8b6d2b2e6f76025709cbd62086657bb749c90f55,mpush-netty/src/main/java/com/mpush/netty/udp/NettyUDPConnector.java,NettyUDPConnector,createServer,#Listener#EventLoopGroup#ChannelFactory#,72
Before Change
initOptions(b);
ChannelFuture f = b.bind(port).sync();//直接绑定端å?£ï¼Œä¸?è¦?指定host,ä¸?ç„¶æ”¶ä¸?åˆ°ç»„æ’æ¶ˆæ?¯
if (f.isSuccess()) {
Logs.Console.info("udp server start success on:{}", port);
After Change
initOptions(b);
//直接绑定端å?£ï¼Œä¸?è¦?指定host,ä¸?ç„¶æ”¶ä¸?åˆ°ç»„æ’æ¶ˆæ?¯
b.bind(port).addListener(future -> {
if (future.isSuccess()) {
logger.info("udp server start success on:{}", port);
if (listener != null) listener.onSuccess(port);
} else {
logger.error("udp server start failure on:{}", port, future.cause());
if (listener != null) listener.onFailure(future.cause());
}
});
} catch (Exception e) {
logger.error("udp server start exception", e);
if (listener != null) listener.onFailure(e);